from jiuyun.celery import task_app
import time


@task_app.task
def add_approve(**item):
    # 处理审批流程
    appr_id = item.get('appr_id')
    print('正在处理中...: %s' % appr_id)
    time.sleep(5)
    print('处理OK: %s' % appr_id)
    return 'Ok'

import kombu